package org.apache.spark

import org.apache.spark.rdd.RDD

/**
 * @DATE 2022/1/6/21:23
 * @Author MDK
 * @Version 2021.2.2
 * */
object CheckPointLoader {
  def load(sc:SparkContext, path:String):RDD[(Int, Int)]={
    val rdd: RDD[(Int, Int)] = sc.checkpointFile(path)
    rdd
  }
}
